package com.thh.schedule;

import com.thh.service.MQService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 一种兜底的解决方案：
 * 利用定时任务的机制--轮询去扫描消息确认表是否存在消息。
 * @Author thh
 * @Description
 * @Version 1.0
 **/
@Component
public class ScheduleTask {

    private static final SimpleDateFormat format = new SimpleDateFormat("HH:mm:ss");

    @Autowired
    MQService mqService;


    @Scheduled(fixedRate = 3000)
    public void reportCurrentTime(){
        // 把状态为0的消息查询查询来，重新循环调用发送
       /* for (int i = 0; i < 10; i++) {
            mqService.sendMsg(json);
        }*/
        System.out.println("当前时间：" + format.format(new Date()));
    }
}
